package org.example

import org.apache.spark.sql.SparkSession

object spark_read_mysql2 {
  def main(args: Array[String]): Unit = {

    //创建SparkSession，作用：连接Spark
    val spark = SparkSession
      .builder()
      .master("local[*]") //指定运行的方式
      .appName("spark_read_mysql2") //程序的名字
      .getOrCreate()

    //创建DataFrame
    val jdbcDF = spark.read.format("jdbc")
      .option("url", "jdbc:mysql://192.168.152.121:3306/spark")
      .option("dbtable", "student")
      .option("user", "root")
      .option("password", "123456")
      .load()

    //在终端显示DataFrame的内容
    jdbcDF.show()
  }
}
